package main

import (
	"logSlicer/internal/app/slicer"
	"logSlicer/internal/pkg/log"
	"runtime"
	"sync"
)

func main() {
	defer log.Flush()

	numCPU := runtime.NumCPU()
	runtime.GOMAXPROCS(numCPU)
	var wg sync.WaitGroup

	wg.Add(1)
	go slicer.ProductThread()
	go slicer.ConsumeThread()

	wg.Wait()
}
